var db = require('../../config/db')
exports.search = (req,res)=>{
    if(req.query.tar == '1'){
        //
    db.query(`select * from landres_review where userid=?`, req.query.id,(err, results)=>{
        if(err) return res.cc('500', err)
        if(results.length < 1) return res.cc('404', '记录为空')
        res.send({ //返回前端信息
            status: 200,
            message: '查询成功',
            data: results,
        })
    })  
    }else{
        //管理员
        db.query(`select * from landres_review`, (err, results) => {
            if (err) return res.cc('500', err);
            if (results.length < 1) return res.cc('404', '记录为空');
        
            // 使用 Promise.all() 来处理所有的数据库查询操作
            Promise.all(results.map(record => {
                return new Promise((resolve, reject) => {
                    db.query(`select * from user_info where id=?`, [record.userid], (err, results1) => {
                        if (err) return reject(err);
                        record.owner = results1[0].name; // 添加 owner 字段
                        //console.log(results1[0].name)
                        resolve();
                    });
                });
            })).then(() => {
                // 所有的数据库查询操作完成后，发送响应
                res.send({
                    status: 200,
                    message: '查询成功',
                    data: results,
                });
            }).catch(err => {
                // 处理错误
                return res.cc('500', err);
            });
        });
    }
}

//更新
exports.up = (req, res)=>{
    if(req.body.status == 'agress'){//同意审核
        db.query('UPDATE landres_review SET status=? WHERE id=?', ['已通过' , req.body.id],(err, results)=>{
        if(err) return res.cc('404',err)
        if(results.affectedRows !== 1) return res.cc('500','审核操作失败，请重新尝试')
        db.query('select *from landres_review  where id=?', req.body.id,(err, results1)=>{
        const recordToInsert = {
            name: results1[0].landresname,
            parcelcount: results1[0].parcelcount,
            address: results1[0].address,
            userid: results1[0].userid
        };
        db.query('INSERT INTO land_resource SET ?', recordToInsert, (err, results2) => {
            if (err) return res.cc('404', err.message);
            if (results2.affectedRows !== 1) return res.cc('404', '添加失败，请稍后再试');
            res.send({ status: 200, message: '操作成功' });
        });
        })
        })
    }else{
        db.query('UPDATE landres_review SET status=?, comments=? WHERE id=?', ['不通过' ,req.body.comments, req.body.id],(err, results)=>{
            if(err) return res.cc('404',err)
            if(results.affectedRows !== 1) return res.cc('500','审核操作失败，请重新尝试')
            res.send({ status: 200, message: '操作成功' });
        })

    }
  }
